package com.yichat.micro.msghttpservice.core.metrics;

import com.yichat.micro.msghttpservice.core.record.batch.MultiChildRecordBatch;
import com.yichat.micro.msghttpservice.core.record.batch.RecordBatch;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @功能:
 * @作者:chanson
 * @时间:2019/4/22 23:24
 */
@Component
public class RecordExecutorMonitor {

    /**
     * 返回队列可使用数量
     *
     * @return
     */
    public int getQueueRemainNumber() {
        // return recordBatch.
        return -999;
    }

    /**
     * 返回当前活跃线程数量
     *
     * @return
     */
    public int countActiveThread() {
        //    return ((AdvancedExecutor) AsyncRecordServiceImpl.getRecordExecutor()).getActiveThreadNumber().intValue();
        return -999;
    }


}
